package com.cj.rxdo;

import rx.Observable;
import rx.functions.Func1;

/**
 * Created by cj on 2017/3/16.
 */

public class Tranf implements Observable.Transformer<Long,String> {
    @Override
    public Observable<String> call(Observable<Long> integerObservable) {
        return integerObservable.map(new Func1<Long, String>() {
            @Override
            public String call(Long integer) {
                return String.valueOf(integer)+"--trans--";
            }
        });
    }
}
